<?php

namespace crmeb\command;

use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\facade\Db;
use Redis;
class Convert extends Command
{
    /**
     * @var int
     */
    protected $timer;

    /**
     * @var int|float
     */
    protected $interval = 1;

    // 配置定时器的信息
    protected function configure()
    {
        $o = new Output();
        // 设置脚本的命令名字
        $this->setName('convert')->setDescription('测试！');
    }
    protected function execute(Input $input, Output $output)
    {
        $redis = new Redis();
        $redis->connect('localhost', 6379);
        $redis->subscribe(['haha'], function ($redis, $channel, $message) {
            $o = new Output();
            // 处理收到的消息
            $o->writeln($message);
            if($message){
                Db::table('ux_test')->where('id', 2)->update(['q' => $message]);
            }
        });
        // 输出到日志文件
//        $output->writeln("TestCommand:");
//        // 定时器需要执行的内容
//        $output->writeln("end....");
    }
}